﻿using System.Text;

namespace test.kafka
{
    public interface IBus
    {
        void Publish<TEventMessage>(TEventMessage message) where TEventMessage : IEventMessage;
        void Subscribe<TEventMessage>( IEventHandler<TEventMessage> handler) where TEventMessage : IEventMessage;
    }

   
}
